//package cn.xiaolang.function.connection;
//
//import java.sql.Connection;
//import java.sql.PreparedStatement;
//import java.sql.SQLException;
//import java.util.List;
//import java.util.Map;
//
//import javax.sql.DataSource;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;
//import org.springframework.jdbc.core.JdbcTemplate;
//import org.springframework.jdbc.core.PreparedStatementCreator;
//import org.springframework.jdbc.support.GeneratedKeyHolder;
//import org.springframework.jdbc.support.KeyHolder;
//
//
///**
// * jdbc连接mysql;
// *
// * @author fuhw
// * @date 2017年7月27日 下午3:59:11
// */
//public class ConnectMySqlByJdbc {
//
//
//	private static final Logger log = LoggerFactory.getLogger(ConnectMySqlByJdbc.class);
//
//
//	public static JdbcTemplate sourceJdbc;
//	public static JdbcTemplate targetJdbc;
//
//	static {
//		DataSourceBuilder source = DataSourceBuilder.create();
//		source.driverClassName("com.mysql.jdbc.Driver");
//		source.url("jdbc:mysql://127.0.0.1:3306/bxj-old");
//		source.username("root");
//		source.password("root");
//		DataSource originDataSource = source.build();
//		sourceJdbc = new JdbcTemplate(originDataSource);
//
//		DataSourceBuilder target = DataSourceBuilder.create();
//		target.driverClassName("com.mysql.jdbc.Driver");
//		target.url("jdbc:mysql://127.0.0.1:3306/bxj-new");
//		target.username("root");
//		target.password("root");
//		DataSource targetDataSource = target.build();
//		targetJdbc = new JdbcTemplate(targetDataSource);
//	}
//
//
//	public static void main(String[] args) {
//		log.info("开始查询指定数据库中某表的记录：");
//		String querySql = "select a.* from `bxj-new`.sys_user a";
//		List<Map<String, Object>> queryResult = targetJdbc.queryForList(querySql);
//		log.info("查询结果：{}",queryResult);
//
//		log.info("开始向指定数据库中插入记录：");
//		String insertSql = "insert into `bxj-old`.tb_datas(`name`,`details`) Values('xiaolang','this is a test')";
//		KeyHolder keyHolder = new GeneratedKeyHolder();
//		sourceJdbc.update(new PreparedStatementCreator() {
//			@Override
//			public PreparedStatement createPreparedStatement(Connection conn) throws SQLException {
//				return conn.prepareStatement(insertSql, PreparedStatement.RETURN_GENERATED_KEYS);
//			}
//		}, keyHolder);
//
//		log.info("新增记录返回的主键ID为：{}",keyHolder.getKey().intValue());
//
//	}
//}
//
//
